'''
Celery 将生产者和消费者关联起来
导入
配置
创建实例对象
配置消息队列（broker）可以实现消息队列的功能
'''

from celery import Celery
import os

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings")
#main 一般习惯性讲工程的名字作为参数值，确保celery实例唯一
app = Celery('celery_tasks')
#config_from_object直接写配置文件路径
app.config_from_object('celery_tasks.config')
'''
生产者
    需要单独创建一个任务包，任务包中的py文件必须一tasks.py作为文件名
    生产者/函数本质上一个函数
    必须经过celery的实例对象的task装饰器装饰

'''

#消费者
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

# celery -A celery_tasks.main worker -l info
#